a5d2255fce445946b61e8b21ac1f054d4cdafcb3,src/test/java/reactor/core/publisher/FluxPublishOnTest.java,FluxPublishOnTest,normalSyncFusedBackpressured,#,163

Before Change



	@Test
	public void normalSyncFusedBackpressured() throws Exception {
		AssertSubscriber<Integer> ts = AssertSubscriber.create(0);

		Flux.range(1, 1_000_000)
		    .publishOn(Schedulers.fromExecutorService(exec))
		    .subscribe(ts);

		ts.assertNoValues()
		  .assertNoError()
		  .assertNotComplete();

		ts.request(500_000);

		Thread.sleep(500);

		ts.assertValueCount(500_000)
		  .assertNoError()
		  .assertNotComplete();

		ts.request(500_000);

		ts.await(Duration.ofSeconds(10));
		ts.assertTerminated();

		ts.assertValueCount(1_000_000)

After Change



	@Test
	public void normalSyncFusedBackpressured() throws Exception {
		StepVerifier.create(Flux.range(1, 1_000_000)
		                        .publishOn(Schedulers.fromExecutorService(exec)), 0)
		            .thenRequest(500_000)
		            .expectNextCount(500_000)
		            .thenRequest(500_000)
		            .expectNextCount(500_000)
		            .verifyComplete();
	}

	@Test